package jupitermouse.site.project.dataclean

import org.apache.spark.sql.SparkSession

object SparkStatCleanJob {
  def main(args: Array[String]): Unit = {
    var spark = SparkSession.builder()
      .appName("SparkStatCleanJob")
      .master("local[2]")
      .getOrCreate()

    val accessRDD = spark.sparkContext.textFile("file:///E:\\workroom\\learn\\spark\\access-1000.log")

//    val accessDF = spark.createDataFrame(accessRDD.map())
  }
}
